6b35d65b44a3a60d99492c8786854e7dd4634b1e,src/test/java/org/graylog/plugins/beats/BeatsCodecTest.java,BeatsCodecTest,decodeMessagesHandleGenericBeatMessages,#,122

Before Change


    public void decodeMessagesHandleGenericBeatMessages() throws Exception {
        final byte[] json = Resources.toByteArray(Resources.getResource("BeatsCodecTest/generic.json"));
        final RawMessage rawMessage = new RawMessage(json);
        final Collection<Message> messages = codec.decodeMessages(rawMessage);
        assertThat(messages)
                .isNotNull()
                .hasSize(1);
        final Message message = messages.iterator().next();
        assertThat(message.getSource()).isEqualTo("unknown");
        assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));
        assertThat(message.getField("facility")).isEqualTo("genericbeat");

After Change


    public void decodeMessagesHandleGenericBeatMessages() throws Exception {
        final byte[] json = Resources.toByteArray(Resources.getResource("generic.json"));
        final RawMessage rawMessage = new RawMessage(json);
        final Message message = codec.decode(rawMessage);
        assertThat(message).isNotNull();
        assertThat(message.getSource()).isEqualTo("unknown");
        assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));